package cn.tx.receive;

/**
 * 手动签收
 * @author Mxb
 * @version 1.0
 * @date 2020/10/12 21:56
 */
//@Component
//public class MessageReceive1 {
//    @RabbitListener(bindings = {
//            @QueueBinding(value = @Queue("queue"),
//                    key = "error",
//                    exchange = @Exchange(value = "directs"))//默认的直连交换机
//    })
//    public void receiveMessage(String content, Message message, Channel
//            channel) throws IOException {
//        System.out.println("消费者收到消息-内容为:" + content);
//        System.out.println("消费者收到消息-消息对象:" + message);
//        System.out.println("消费者收到消息-信道:" + channel);
//        // 获取消息投递ID
//        long deliveryTag = message.getMessageProperties().getDeliveryTag();
//        System.out.println("消息投递ID:" + deliveryTag);
//
//        String messageId = message.getMessageProperties().getMessageId();
//        System.out.println("消息自定义ID:" + messageId);
//        /**
//         * 参数说明:
//         * deliveryTag 消息投递ID，要签收的投递ID 是多少
//         * multiple:是否批量签收
//         */
//        //配置手动签收后，告诉系统确认手动签收
//        channel.basicAck(deliveryTag, false);
//        System.out.println("消息签收成功");
//        System.out.println("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~");
//    }
//}
